package org.ruizhijie.run;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.ruizhijie.topic.TopicQueue;
import org.ruizhijie.topic.i.impl.OutPortSubcriberImpl;

public class OutPort implements Runnable{
	private Logger log = LogManager.getLogger(LogManager.ROOT_LOGGER_NAME);
	
	public OutPort(TopicQueue tq,String topic,String host,int port){
		// 订阅
		new OutPortSubcriberImpl(tq, topic,host,port);
		log.info("初始化outPort完成-----"+host+"-----"+port);
	}
	
	
	@Override
	public void run() {
	}

}
